package task

import (
	service "github.com/beherochuling/beesoft_api/app/service/text"
	"github.com/gogf/gf/v2/net/ghttp"
)

var TaskStream taskStream

type taskStream struct{}

func (receiver *taskStream) Sse(r *ghttp.Request) { // 创建任务
	ctx := r.Context()

	service.TaskStream.Sse(ctx, r)
}
